ab96dd8af3db2d9251420f6fc51bda5bdf2a8d1d,java/src/org/exist/jms/replication/publish/ReplicationTrigger.java,ReplicationTrigger,afterDeleteDocument,#DBBroker#Txn#XmldbURI#,219
Before Change
@Override
public void afterDeleteDocument(final DBBroker broker, final Txn transaction, final XmldbURI uri) throws TriggerException {
if (LOGGER.isDebugEnabled()) {
LOGGER.debug(uri.toString());
}
if (isJMSOrigin(transaction)) {
LOGGER.info(String.format(BLOCKED_MESSAGE, uri.toString()));
return;
}
After Change
@Override
public void afterDeleteDocument(final DBBroker broker, final Txn transaction, final XmldbURI uri) throws TriggerException {
LOGGER.info("Delete document '{}'", uri.toString());
if (!guard.getReplicationEnabled()) {
LOGGER.info(REPLICATION_OFF);
return;
}
if (isJMSOrigin(transaction)) {
LOGGER.info(BLOCKED_MESSAGE, uri.toString());
return;
}